package com.celeritymq.handler;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;

import com.celeritymq.utils.CelerityBuffer;

public interface CelerityReader extends Runnable {
	void register(SocketChannel sc) throws IOException;

	void processRead(SelectionKey sk) throws IOException;
}
